package com.yytek.am.core.runtime;

import akka.actor.ActorRef;
import com.yytek.am.core.msg.MqConfigUpdateMessage;
import com.yytek.common.client.base.MqConfig;

import java.util.List;

public class EventIOManager {
	private ActorRef ioActor;

	public EventIOManager(ActorRef ioActor) {
		this.ioActor = ioActor;
	}

	public void addSource(MqConfig mqConfig, List<String> topicList) {
		this.ioActor.tell(new MqConfigUpdateMessage(mqConfig, topicList), ActorRef.noSender());
	}
}
